package com.event.streaming.config.setttings

import scala.concurrent.duration.Duration

trait StreamingConsumerSettings extends KafkaSettings with DebugSettings {
  //streaming interval in seconds
  def streamingInterval:Duration

  //pooling batch size
  def streamingBatchSize:Int

  //the length of a window
  def windowLength:Duration
  def slidingInterval:Duration

}
